#if defined(MODEL_ROOMS)    

#include <string>
#include <mutex>
#include "DeviceInfo.h"

using namespace std;


namespace Media{

class kafkaService{
public:
    static kafkaService *instance();
    bool startReportThd();
    bool kafkaService::reportMessage(string brokers, string topic, string message, string username, string password);
private:
    kafkaService(){}
    ~kafkaService(){}
private:
    //上报消息内容，目前线写死devInfo类型，线写死一个string
    static kafkaService *sm_deviceInfoInstance;
    static mutex      sm_instanceLock;
    DeviceInfo m_curDevInfo;
    bool       m_reportMark = false;
    bool       m_reportExit = true;
};

}

#endif
